85b9b4c6798d29161b84901771c9b3e65e81289d,src/main/java/fr/pilato/elasticsearch/crawler/fs/client/ElasticsearchClient.java,ElasticsearchClient,bulk,#BulkRequest#,100
Before Change
logger.trace("{}", sbf);
StringEntity entity = new StringEntity(sbf.toString(), Charset.defaultCharset());
Response restResponse = client.performRequest("POST", "/_bulk", Collections.emptyMap(), entity);
BulkResponse response = JsonUtil.deserialize(restResponse, BulkResponse.class);
logger.debug("bulk response: {}", response);
return response;
After Change
Map<String, String> params;
if (pipeline != null) {
params = new HashMap<>(1);
params.put("pipeline", pipeline);
} else {
params = Collections.emptyMap();
}
StringEntity entity = new StringEntity(sbf.toString(), Charset.defaultCharset());